package com.fulihui.information.core.zbus;

import com.fulihui.information.biz.content.SpiderDataProcessBiz;
import com.fulihui.information.common.config.AppConst;
import com.sun.corba.se.pept.broker.Broker;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;

/**
 * @author leeson 2016年5月6日 下午7:21:43
 * 短消息队列 消费者 （随容器启动）
 */
@Component
@Slf4j
public class ZbusConsumerHandle {
    @Autowired
    private AppConst appConst;
    @Autowired
    private SpiderDataProcessBiz spiderDataProcessBiz;
    private Broker broker;

    public static final int PROCESSOR_COUNT = 2 * Runtime.getRuntime().availableProcessors();

    @PostConstruct
    public void init() throws Exception {


    }

    @PreDestroy
    public void destroy() {

    }
}